#include "mysql_helper.h"
#include <stdio.h>
#include <string.h>

extern MYSQL *mysql_connect;


void 
print_mysql_error(const char *msg)
{
    if (msg != NULL)
    {
        printf("%s: %s\n", msg, mysql_error(mysql_connect));
    }
    else
    {
        printf("%s\n", mysql_error(mysql_connect));
    }
}

/* 执行sql */
int 
executesql(const char * sql) 
{
    if (mysql_real_query(mysql_connect, sql, strlen(sql)) != 0)
    {
        return (-1);
    }
    return (0);
}

/* 执行查询 */
MYSQL_RES *
findsql(const char *sql)
{
    if (executesql(sql) != 0)
    {
        return (NULL);
    }
    return (mysql_store_result(mysql_connect));
}

/* 执行sql插入数据 */
int
insertsql(const char *sql)
{
    int result = -1;
    if (mysql_query(mysql_connect, sql) == 0)
    {
        result = mysql_affected_rows(mysql_connect);
    }
    return (result);
}